package com.baosight.xdata;

import com.baosight.xdata.redis.LettuceUtil;
import com.baosight.xdata.redis.TssLettuceForSingleNodeUtil;
import io.lettuce.core.RedisURI;

import java.time.Duration;
import java.util.HashSet;
import java.util.Set;

public class Test {
    public static void main(String[] args) {
        RedisURI redisURI = RedisURI.builder().withHost("10.25.10.102").withPort(6378).withTimeout(Duration.ofSeconds(30)).build();
        TssLettuceForSingleNodeUtil.init(redisURI);


        //for(int i=0;i<10;i++){
            StreamConsumer streamConsumer = new StreamConsumer();
            Thread consumerThread = new Thread(streamConsumer);
           consumerThread.start();
        //}
    }
}
